package com.xhu.dao.impl;

import com.xhu.bean.pojo.Emp;
import com.xhu.dao.EmpDao;
import com.xhu.utils.ConnectionFactory;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;

import java.sql.Connection;
import java.sql.SQLException;

public class EmpDaoImpl implements EmpDao {
    @Override
    public Emp login(String username, String password) {
        Emp emp=null;
        //与数据库对应  相应 sql语句  数据库的字段必须与 实体类的字段一一对应
        String  sql="select emp_loginid,emp_pwd" +
                " from emp where  emp_loginid=?  and emp_pwd=? ";
        //获得连接对象
        Connection connection= ConnectionFactory.openConnection();
        //执行对象
        QueryRunner queryRunner=new QueryRunner();
        try {
            //  数据库的名字 和 实体类必须保持一致
            emp = queryRunner.query(connection, sql, new BeanHandler<Emp>(Emp.class), username, password);
        } catch (SQLException e) {
            System.err.println("sql:"+sql);
            System.err.println("参数:"+username+"&"+password);
        }finally {//最终都会被执行的代码
            ConnectionFactory.closeConnection(connection);
        }
      /*  //或者执行
        Statement   statement= connection.createStatement();
        //执行sql 获得结果集
        //结果集封装
        //释放资源*/
        return emp;
    }
}
